package org.future.task.core.handler;

import java.util.List;

public interface Connection {

    List<Object> getDataList(String queueName, int size, int timeOut);

    long size(String queueName);

    void sendDataList(String queueName, List<?> dataList) throws Exception;

    void sendData(String queueName, Object data) throws InterruptedException;

    String getType();

    Commit getCommit();


}
